package com.dyna.cp.kafka.service;

import java.util.List;

public interface KafkaService {

    /**
     * 测试kafka消息通知
     * @param msg msg
     */
    void testKafka(String msg);

    /**
     * 测试回滚kafka消息是否通知成功
     * @param msg 消息
     */
    void kafkaRollback(String msg);

    /**
     * kafka顺序消费消息
     */
    void orderConsumerMsg();

    /**
     * 测试kafka发送到指定分区
     * @param topic 主题
     * @param partition 分区
     * @param key key
     * @param msg 消息
     */
    void sendDesignatePartition(String topic, Integer partition, String key, String msg);

    /**
     * 批量生产消息
     * @param msgList 消息列表
     */
    void batchProductMsg(List<String> msgList);

}
